package cn.mldn.microcloud.service;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface MySink {
	String INPUT = "myMessageInPut";
	String INPUT2 = "myMessageInPut2";
	
	@Input(INPUT)
	SubscribableChannel input();//消息输入，接收消息
	
	@Input(INPUT2)
	SubscribableChannel input2();//消息输入，接收消息

}
